package com.yitiao.mq;

import com.yitiao.consumer.MessageHandler;
import com.yitiao.annotation.MessageHandlerSign;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;

@MessageHandlerSign(name = "exchange-1,yitiao,queue-1")
@Slf4j
public class DefaultMessageHandler implements MessageHandler {

    @Override
    public void handleMessage(Message message) {
        log.info("DefaultMessageHandler receive message:[{}]",new String(message.getBody()));
    }
}
